package client

import (
	"github.com/streadway/amqp"
)

func InitMq(appConfig *Config) *amqp.Connection {
	// 初始化RabbitMQ
	conn, err := amqp.Dial(appConfig.RabbitMQ.Addr)
	if err != nil {
		panic(err)
	}
	return conn
}
